#include "PthreadPoolCplus.h"

void* func(void*)
{
	sleep(1);
	printf("func\n");
	fflush(stdout);
}

int main()
{

	CPthreadPool cPthreadPool;
	cPthreadPool.pool_create();
	for(float i =0; i <100000; i++)
	{
		cPthreadPool.pool_add_work(&func,NULL);
	
	}
	sleep(10);
	/*
	for(float i =0; i <20; i++)
	{
		cPthreadPool.pool_add_work(&func,NULL);
	}
	sleep(1);
	for(float i =0; i <20; i++)
	{
		cPthreadPool.pool_add_work(&func,NULL);
	}
	sleep(1);
	for(float i =0; i <20; i++)
	{
		cPthreadPool.pool_add_work(&func,NULL);
	}
	sleep(1);
	for(float i =0; i <20; i++)
	{
		cPthreadPool.pool_add_work(&func,NULL);
	}
	*/
	sleep(10);
	return 0;
}
